cd2bd5e25e40f8968960ed5767c311c51a77bccc,ch03/src/main/java/client/CRUDExample.java,CRUDExample,main,#String[]#,22
Before Change
Connection connection = ConnectionFactory.createConnection(conf);
Table table = connection.getTable(TableName.valueOf("testtable"));
Put put = new Put(Bytes.toBytes("myrow-1"));
put.add(Bytes.toBytes("fam-A"), Bytes.toBytes("col-A"),
Bytes.toBytes("val-1"));
put.add(Bytes.toBytes("fam-B"), Bytes.toBytes("col-B"),
Bytes.toBytes("val-2"));
table.put(put);
Get get = new Get(Bytes.toBytes("myrow-1"));
get.addColumn(Bytes.toBytes("fam-A"), Bytes.toBytes("col-A"));
Result result = table.get(get);
System.out.println(result);
byte[] val = result.getValue(Bytes.toBytes("fam-A"),
Bytes.toBytes("col-A"));
After Change
Connection connection = ConnectionFactory.createConnection(conf);
Table table = connection.getTable(TableName.valueOf("testtable"));
) {
Put put = new Put(Bytes.toBytes("row1"));
put.add(Bytes.toBytes("colfam1"), Bytes.toBytes("qual1"),
Bytes.toBytes("val1"));
put.add(Bytes.toBytes("colfam2"), Bytes.toBytes("qual2"),
Bytes.toBytes("val2"));
table.put(put);
Scan scan = new Scan();
ResultScanner scanner = table.getScanner(scan);
for (Result result2 : scanner) {
while (result2.advance())
System.out.println("Cell: " + result2.current());
}
Get get = new Get(Bytes.toBytes("row1"));
get.addColumn(Bytes.toBytes("colfam1"), Bytes.toBytes("qual1"));
Result result = table.get(get);
System.out.println("Get result: " + result);
byte[] val = result.getValue(Bytes.toBytes("colfam1"), Bytes.toBytes("qual1"));
System.out.println("Value only: " + Bytes.toString(val));